package com.example.kafka.config;

/**
 * 流数据的监听消费者实现的接口类，系统自动会通过
 * KafkaStreamListenerFactory类扫描项目中实现该接口的类
 * 并注册为流数据的消费端
 * 其中泛型可是KStream或KTable
 * @author Liyuhang
 * @param <T>
 */
public interface KafkaStreamListener<T> {

    /**
     * 输入topic
     * @return
     */
    String inPutTopic();

    /**
     *  输出topic
     * @return
     */
    String outPutTopic();

    /**
     * 具体处理逻辑
     * @param stream
     * @return
     */
    T handle(T stream);

}
